package com.fxkj.cloud.drms.infra.mq.mqtt;

import com.fxkj.cloud.drms.infra.config.MqttConfigConstants;
import com.fxkj.cloud.drms.infra.utils.AbstractListeningExecutor;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

/**
 * <p>description: </p>
 * @author ww
 * @date 2025/3/14 11:40
 */
@Component
public class MqttExecutorService extends AbstractListeningExecutor {

    @Value(MqttConfigConstants.MQTT_SUBSCRIBE_POOL_SIZE_EXPRESSION)
    private int mqttExecutorThreadPoolSize;

    @Override
    protected int getThreadPollSize() {
        return mqttExecutorThreadPoolSize;
    }
}
